#include <etcd/Client.hpp>
#include <etcd/KeepAlive.hpp>
#include <etcd/Response.hpp>
#include <thread>

int main(int argc, char* argv[])
{
    std::string etcd_host = "http://127.0.0.1:2379";
    // 实例化客户端对象
    etcd::Client client(etcd_host);


    // 获取/创建租约保活对象 -- 能指定有效时长的租约
    auto keep_alive = client.leasekeepalive(3).get();
    //leasekeepalive会创建一个keepalive对象(创建对象的时候, 会自动有一个ID)
    //为什么还要get? pplx::task<std::shared_ptr<KeepAlive>> leasekeepalive(int ttl); 返回一个task, task取到里面的类型需要用get
    //auto 的类型为智能指针

    // 获取租约ID
    auto lease_id = keep_alive->Lease();
    // 向etcd新增数据
    auto resp = client.put("/service/user", "127.0.0.1:8080", lease_id).get();//pplx::task<Response> put(...)
    /*
    class Response{
        bool is_ok()
        std::string const& error_message()
        Value const& value()//当前的数值 或者 一个请求的处理结果
        Value const& prev_value()//之前的数值
        Value const& value(int index)
    };
    */
    if(resp.is_ok() == false) {
        std::cout << "新增数据失败: " << resp.error_message() << std::endl;
        return -1;
    }
    //keepalive会和etcd服务端建立长连接, 创建一个ID, 并一直发送心跳包, 发送ttl秒, 然后客户端拿着这个ID去put, 这样就建立起了联系
    //如果服务器没接收到心跳包了, 则会将有这个ID的数据删除

    auto resp2 = client.put("/service/friend", "127.0.0.1:9090").get();
    if (resp2.is_ok() == false) {
        std::cout << "新增数据失败: " << resp2.error_message() << std::endl;
        return -1;
    }

    std::this_thread::sleep_for(std::chrono::seconds(10)); //阻塞休息10s
    return 0;
}